#!/bin/bash
#主机地址
read -p  "输入IP地址:"  addr
#oracle用户名
read -p "输入用户名:" user
#oracle用户密码
read -p "输入密码:" pwd

# 定义 ETL 时间
dt=`date -d '1 days ago' '+%y%m%d'`

# 定义表名数组
arr_tab=(AML_CUSTOMER_MASTER AML_ACCOUNT_MASTER AML_TRANSACTION_DETAIL AML_UBO_INFO AML_WATCHLIST_MASTER AML_WATCHLIST_DETAIL AML_SCREENING_RESULT AML_ALERT AML_SUSPICIOUS_TXN_REPORT AML_MONITORING_RULE)
for v_tab in "${arr_rab[@]}"
do
sqoop import \
--connect jdbc:oracle:thin:@"$addr":orcl \
--username "$user" \
--password "$pwd" \
#源表明
--table "$v_tab" \
#处理null值
--null-string '\\N' \
--null-non-string '\\N' \
#指定hive数据库
--hcatalog-database bigdata \
#传入hive目标表名
--hcatalog-table "ODS_$v_tab" \
#分区字段名
--hive-partition-key "etl_dt" \
#分区字段值
--hive-partition-value "$dt" \
#如果目录存在先执行删除
--delete-target-dir \
#1个map任务
-m 1
done
echo "导入结束"

